export default function(app) {
  const { socket } = app.locals;
  // 客户端订阅
  socket.on('subscribe', function(data, cb) {
    // 加入房间
    socket.join(data.roomId);

    // 通知当前房间的其他人，但是自己并不收到消息
    socket.broadcast.to(data.roomId).emit('subscribe', data);

    // 回调
    cb({data: 'ok'})
  });
}
